handle stream processing